package com.learn.redis.mq;

import cn.learn.mq.core.pubsub.AbstractChannelMessageListener;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @author : 翌擎科技
 * @date : 2022/7/26 17:40
 */
@Component
@Slf4j
public class MessageCustomer extends AbstractChannelMessageListener<MessageTest> {
    @Override
    public void onMessage(MessageTest message) {
        log.info("[onMessage][收到 message 刷新消息]:{}",message);
    }
}
